github.com/go-pg/pg/v10.baseDB.opt (field)
55 uses
github.com/go-pg/pg/v10 (current package)
base.go#L16: opt *Options
base.go#L35: opt: db.opt,
base.go#L50: newopt := *db.opt
base.go#L55: cp.opt = &newopt
base.go#L71: return internal.RetryBackoff(retry, db.opt.MinRetryBackoff, db.opt.MaxRetryBackoff)
base.go#L105: if db.opt.TLSConfig != nil {
base.go#L106: err := db.enableSSL(ctx, cn, db.opt.TLSConfig)
base.go#L112: err := db.startup(ctx, cn, db.opt.User, db.opt.Password, db.opt.Database, db.opt.ApplicationName)
base.go#L117: if db.opt.OnConnect != nil {
base.go#L119: return db.opt.OnConnect(ctx, newConn(ctx, db.withPool(p)))
base.go#L198: return db.opt.RetryStatementTimeout
base.go#L244: for attempt := 0; attempt <= db.opt.MaxRetries; attempt++ {
base.go#L314: for attempt := 0; attempt <= db.opt.MaxRetries; attempt++ {
base.go#L401: err = cn.WithWriter(ctx, db.opt.WriteTimeout, func(wb *pool.WriteBuffer) error {
base.go#L408: err = cn.WithReader(ctx, db.opt.ReadTimeout, readCopyInResponse)
base.go#L414: err = cn.WithWriter(ctx, db.opt.WriteTimeout, func(wb *pool.WriteBuffer) error {
base.go#L425: err = cn.WithWriter(ctx, db.opt.WriteTimeout, func(wb *pool.WriteBuffer) error {
base.go#L433: err = cn.WithReader(ctx, db.opt.ReadTimeout, func(rd *pool.ReaderContext) error {
base.go#L483: err = cn.WithWriter(ctx, db.opt.WriteTimeout, func(wb *pool.WriteBuffer) error {
base.go#L490: err = cn.WithReader(ctx, db.opt.ReadTimeout, func(rd *pool.ReaderContext) error {
base.go#L537: return cn.WithWriter(c, db.opt.WriteTimeout, func(wb *pool.WriteBuffer) error {
base.go#L546: if err := cn.WriteBuffer(c, db.opt.WriteTimeout, wb); err != nil {
base.go#L551: if err := cn.WithReader(c, db.opt.ReadTimeout, func(rd *pool.ReaderContext) error {
base.go#L565: if err := cn.WriteBuffer(c, db.opt.WriteTimeout, wb); err != nil {
base.go#L570: if err := cn.WithReader(c, db.opt.ReadTimeout, func(rd *pool.ReaderContext) error {
base.go#L592: err := cn.WithWriter(c, db.opt.WriteTimeout, func(wb *pool.WriteBuffer) error {
base.go#L601: err = cn.WithReader(c, db.opt.ReadTimeout, func(rd *pool.ReaderContext) error {
base.go#L613: err := cn.WithWriter(c, db.opt.WriteTimeout, func(wb *pool.WriteBuffer) error {
base.go#L622: err = cn.WithReader(c, db.opt.ReadTimeout, readCloseCompleteMsg)
db.go#L21: opt: opt,
db.go#L48: return fmt.Sprintf("DB<Addr=%q%s>", db.opt.Addr, db.fmter)
db.go#L53: return db.opt
listener.go#L173: err := cn.WithWriter(ctx, ln.db.opt.WriteTimeout, func(wb *pool.WriteBuffer) error {
listener.go#L206: err := cn.WithWriter(ctx, ln.db.opt.WriteTimeout, func(wb *pool.WriteBuffer) error {
messages.go#L81: err := cn.WithWriter(c, db.opt.WriteTimeout, func(wb *pool.WriteBuffer) error {
messages.go#L89: return cn.WithReader(c, db.opt.ReadTimeout, func(rd *pool.ReaderContext) error {
messages.go#L143: err := cn.WithWriter(c, db.opt.WriteTimeout, func(wb *pool.WriteBuffer) error {
messages.go#L151: err = cn.WithReader(c, db.opt.ReadTimeout, func(rd *pool.ReaderContext) error {
messages.go#L239: err := cn.WithWriter(c, db.opt.WriteTimeout, func(wb *pool.WriteBuffer) error {
messages.go#L258: err = cn.WithWriter(c, db.opt.WriteTimeout, func(wb *pool.WriteBuffer) error {
messages.go#L330: err = cn.WithWriter(c, db.opt.WriteTimeout, func(wb *pool.WriteBuffer) error {
messages.go#L370: err = cn.WithWriter(c, db.opt.WriteTimeout, func(wb *pool.WriteBuffer) error {
stmt.go#L43: for attempt := 0; attempt <= stmt.db.opt.MaxRetries; attempt++ {
stmt.go#L96: for attempt := 0; attempt <= stmt.db.opt.MaxRetries; attempt++ {
stmt.go#L161: for attempt := 0; attempt <= stmt.db.opt.MaxRetries; attempt++ {
stmt.go#L232: err := cn.WithWriter(c, stmt.db.opt.WriteTimeout, func(wb *pool.WriteBuffer) error {
stmt.go#L240: err = cn.WithReader(c, stmt.db.opt.ReadTimeout, func(rd *pool.ReaderContext) error {
stmt.go#L259: err := cn.WithWriter(c, stmt.db.opt.WriteTimeout, func(wb *pool.WriteBuffer) error {
stmt.go#L267: err = cn.WithReader(c, stmt.db.opt.ReadTimeout, func(rd *pool.ReaderContext) error {
tx.go#L316: for attempt := 0; attempt <= tx.db.opt.MaxRetries; attempt++ {